let MongoClient = require('mongodb').MongoClient;
let objectID =  require('mongodb').ObjectID;
let url = "mongodb://localhost:27017/productManage"; /*连接数据库*/

function _connectDb(callback){
    MongoClient.connect(url,(err,db)=>{
        if(err){
            console.log(err);
            console.log("连接数据库失败");
        }
        callback(db);

    })
}
//暴露objectID模块
exports.ObjectID = objectID;

exports.find=function(collectionname,json,callback){

    _connectDb(function(db){


        let result=db.collection(collectionname).find(json);

        result.toArray(function(error,data){

            db.close();/*关闭数据库连接*/
            callback(error,data);/*拿到数据执行回调函数*/
        })

    })

};
exports.insert=function(collectionname,json,callback){

    _connectDb(function(db){


        db.collection(collectionname).insertOne(json,function (error,data) {
            callback(error,data);
        });

    })

};
exports.update=function(collectionname,json,newjson,callback){

    _connectDb(function(db){


        db.collection(collectionname).updateOne(json,{$set:newjson},function (error,data) {
            callback(error,data);
        });

    })

};
exports.delete=function(collectionname,json,callback){

    _connectDb(function(db){


        let result=db.collection(collectionname).deleteOne(json,function (error,data) {
            callback(error,data);
        });

    })

};